package cn.juque.common.disruptor;

import cn.juque.common.base.DisruptorBody;
import cn.juque.common.base.DisruptorMessage;
import com.lmax.disruptor.EventFactory;

/**
 * @author nuoka
 * @version 1.0.0
 * <li>IntelliJ IDEA</li>
 * <li></li>
 * @date 2021/8/24 22:51
 **/
public class MqEventFactory implements EventFactory<DisruptorMessage<? extends DisruptorBody>> {

    @Override
    public DisruptorMessage<? extends DisruptorBody> newInstance() {
        return new DisruptorMessage<>();
    }
}
